package com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin;

import java.util.List;
import java.util.Map;

import org.springframework.beans.BeanUtils;

import lombok.Data;

@Data
public class HdfsWriter extends UnStructuredWriter {

	private String defaultFS; 
	private boolean haveKerberos;
	private String kerberosKeytabFilePath;
	private String kerberosPrincipal;
	private Map<String, Object> hadoopConfig;
	private String fileType;
	
	
	private List<Column> column;
	
	@Data
	public static class Column{
		
		public Column(String coltype, String colname) {
			this.setType(coltype);
			this.setName(colname);
		}
		/**
		 * name指定字段名，type指定字段类型。 
		 */
		private String name; 
		private String type;
		
	}
	
	
	public HdfsWriter(UnStructuredWriter target) {
		super(target);
	}
}
